640760a2097a28fdcf8d7c3199ac114dfe2e68c8,src/main/java/ru/yandex/clickhouse/ClickHouseStatementImpl.java,ClickHouseStatementImpl,sendStream,#HttpEntity#String#,504

Before Change



            URI uri = new URI("http", null, properties.getHost(), properties.getPort(), "/", query, null);
            HttpPost httpPost = new HttpPost(uri);
            httpPost.setEntity(content);
            HttpResponse response = client.execute(httpPost);
            entity = response.getEntity();
            if (response.getStatusLine().getStatusCode() != HttpURLConnection.HTTP_OK) {

After Change


            URI uri = new URI("http", null, properties.getHost(), properties.getPort(), "/", query, null);
            HttpPost httpPost = new HttpPost(uri);
            if (properties.isDecompress()){
                httpPost.setEntity(new LZ4EntityWrapper(content, properties.getMaxCompressBufferSize()));
            } else {
                httpPost.setEntity(content);
            }
            HttpResponse response = client.execute(httpPost);
            entity = response.getEntity();